import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('81.71.137.167'))
channel = connection.channel()

# 声明一个队列（创建一个队列）
# 如果下面durable=True,代表支持持久化, 否则不支持
# 注意：如果queue已经存在后再durable=True没有效果, 必须是新的队列才行
channel.queue_declare(queue='s13q1', durable=True)

channel.basic_publish(exchange='',
                      routing_key='s13q1',  # 队列的名称
                      body='msg3',
                      properties=pika.BasicProperties(delivery_mode=2))  # 让body持久化

connection.close()
